257a9f736f1996b4a9311e619cd910f02df2bc79,CountCounts/src/CountCounts/Main.java,Main,configure,#,13

Before Change


  public ApplicationSpecification configure() {
    return ApplicationSpecification.builder()
      .addFlow(CountCounts.class)
      .addStream(new Stream("test"))
      .create();
  }
}

After Change


    return ApplicationSpecification.builder()
      .addFlow(CountCounts.class)
      .addQuery(CountQuery.class)
      .addStream(new Stream("text"))
      .addDataSet(new CounterTable(Common.tableName))
      .create();
  }
}